package cn.com.xyc.listener;

import java.io.UnsupportedEncodingException;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;

public class FlushQueueMessage implements MessageListener{

	@Override
	public void onMessage(Message message) {
		try {
			String messageString = new String(message.getBody(),"UTF-8");
			System.out.println(messageString);
		} catch (UnsupportedEncodingException e) {
			e.printStackTrace();
		}
		
	}

}
